
package com.jf.cloud.supplier.service.impl;

import com.jf.cloud.api.auth.bo.UserInfoInTokenBO;
import com.jf.cloud.api.auth.dto.AuthAccountDTO;
import com.jf.cloud.api.auth.feign.AccountFeignClient;
import com.jf.cloud.api.auth.vo.AuthAccountVO;
import com.jf.cloud.common.constant.IsPassShopEnum;
import com.jf.cloud.common.response.ServerResponseEntity;
import com.jf.cloud.common.security.AuthUserContext;
import com.jf.cloud.common.util.IpHelper;
import com.jf.cloud.supplier.dto.ChangeAccountDTO;
import com.jf.cloud.supplier.mapper.SupplierUserMapper;
import com.jf.cloud.supplier.model.SupplierUser;
import com.jf.cloud.supplier.service.SupplierUserAccountService;
import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

/**
 * @author zz
 * @date 2020/09/03
 */
@Service
public class SupplierUserAccountServiceImpl implements SupplierUserAccountService {

    @Resource
    private SupplierUserMapper supplierUserMapper;
    @Autowired
    private AccountFeignClient accountFeignClient;

    @Override
    @GlobalTransactional(rollbackFor = Exception.class)
    @Transactional(rollbackFor = Exception.class)
    public ServerResponseEntity<Void> save(ChangeAccountDTO changeAccountDTO) {
        AuthAccountDTO authAccountDTO = getAuthAccountDTO(changeAccountDTO);
        authAccountDTO.setCreateIp(IpHelper.getIpAddr());
        authAccountDTO.setIsAdmin(0);
        authAccountDTO.setIsPassShop(IsPassShopEnum.YES.value());
        // 保存
        ServerResponseEntity<Long> serverResponseEntity = accountFeignClient.save(authAccountDTO);
        if (!serverResponseEntity.isSuccess()) {
            return ServerResponseEntity.transform(serverResponseEntity);
        }
        SupplierUser supplierUser = new SupplierUser();
        supplierUser.setSupplierUserId(changeAccountDTO.getUserId());
        supplierUser.setHasAccount(1);
        supplierUser.setSupplierId(AuthUserContext.get().getTenantId());
        supplierUserMapper.update(supplierUser);
        return ServerResponseEntity.success();
    }

    @Override
    public ServerResponseEntity<Void> update(ChangeAccountDTO changeAccountDTO) {

        AuthAccountDTO authAccountDTO = getAuthAccountDTO(changeAccountDTO);
        // 更新，不涉及分布式事务
        ServerResponseEntity<Void> serverResponseEntity = accountFeignClient.update(authAccountDTO);
        if (!serverResponseEntity.isSuccess()) {
            return serverResponseEntity;
        }

        return ServerResponseEntity.success();
    }

    @Override
    public ServerResponseEntity<AuthAccountVO> getByUserIdAndSysType(Long userId, Integer sysType) {
        return accountFeignClient.getByUserIdAndSysType(userId,sysType);
    }

    private AuthAccountDTO getAuthAccountDTO(ChangeAccountDTO changeAccountDTO) {
        AuthAccountDTO authAccountDTO = new AuthAccountDTO();
        UserInfoInTokenBO userInfoInTokenBO = AuthUserContext.get();
        authAccountDTO.setPassword(changeAccountDTO.getPassword());
        authAccountDTO.setUsername(changeAccountDTO.getUsername());
        authAccountDTO.setStatus(changeAccountDTO.getStatus());
        authAccountDTO.setSysType(userInfoInTokenBO.getSysType());
        authAccountDTO.setTenantId(userInfoInTokenBO.getTenantId());
        authAccountDTO.setUserId(changeAccountDTO.getUserId());
        authAccountDTO.setEmail(changeAccountDTO.getEmail());
        authAccountDTO.setPhone(changeAccountDTO.getPhone());
        return authAccountDTO;
    }

}
